package cn.iotab.iotkit.transport.api.driver;

import cn.iotab.iotkit.transport.api.common.queue.TransportQueueConfig;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.util.concurrent.TimeUnit;

@Data
@NoArgsConstructor
@AllArgsConstructor
@Builder
public class TransportDriverConfig {

    //session 失效时间
    private long sessionInactivityTimeout = TimeUnit.MINUTES.toMillis(5);
    //session report间隔
    private long sessionReportTimeout = TimeUnit.MINUTES.toMillis(1);
    //pull interval
    private int notificationsPollDuration = 500;

    //队列相关配置
    private TransportQueueConfig queueConfig;

    //rpc channel id
    private String rpcChannelId;
    //queue producer topic
    private String upStreamTopic;
    //queue consumer topic
    private String downStreamTopic;
    private String consumerGroup;

}
